package skewreduce.framework;

import java.util.Set;

import skewreduce.framework.physical.PhysicalOp;


public interface SchedulerEventHandler {
    public void handle(SchedulerEvent event);
    public void handleCompletion(PhysicalOp op);
    public void handleFailed(PhysicalOp op);
    public void handleKilled(PhysicalOp op);
    public void handleRunningSlow(PhysicalOp op);
    public void handleError(PhysicalOp op,Throwable ex);
    public Set<PhysicalOp> reoptimize(Set<PhysicalOp> ops);
}
